package com.seckill.config;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @Author: 胡成
 * @Version: 0.0.1V
 * @Date: 2018/12/7
 * @Description: Direct配置文件
 **/
@Configuration
public class RabbitMQDirectConfig {

    public static final String QUEUE = "direct_queue";

    /**
     * @Author: 胡成
     * @Date:   2018/12/7 9:42
     * @Description: direct模式
    **/
    @Bean
    public Queue directQueue(){
        //第一个参数是队列名称，第二个参数是指是否持久化
        return new Queue(QUEUE,true);
    }

}
